package org.apache.flink.state

import org.apache.flink.api.common.functions.RichFlatMapFunction
import org.apache.flink.util.Collector

class AvgWithValueState extends RichFlatMapFunction[(Long,Long), (Long, Double)]{

    override def flatMap(in: (Long, Long), collector: Collector[(Long, Double)]): Unit = {

    }
}
